<?php

// 异步mysql


//实例化资源
$db = new swoole_mysql();

$config = [
    'host' => '192.168.50.145',
    'user' => 'root',
    'password' => 'root',
    'database' => 'mysql',
    'charset' => 'utf8',
];

//连接数据库
$db->connect($config, function ($db, $r) {
    if (!$r) {
        var_dump($db->connect_errno, $db->connect_error);
        echo "连接失败\n";
        return;
    }
    //执行sql语句
    $db->query("select * from user", function (swoole_mysql $db, $r) {
        
        if($r === false){
            var_dump($db->error);
            die("操作失败");
        }elseif($r === true){
            var_dump($db->affected_rows, $db->insert_id);
        }

        var_dump($r);
        $db->close();   //关闭连接
    });
});

